package com.wnxy.admin.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class JRabbitMQConfig {

    //创建一个队列，修改状态为"故障"，就发送消息
    @Bean
    public Queue queueJ01(){
        return QueueBuilder.durable(MessageQueueConfig.FAULT_QUEUE).build();
    }

}
